package com.example.config;

//@Configuration
//@Slf4j
//public class NettyConfig {
//    @Bean
//    public wsserver createNettyServer() {
//        ScheduledExecutorService  executorService = Executors.newScheduledThreadPool(1);
//        wsserver instance = wsserver.getInstance();
//        //启动Netty服务，使用新的线程启动
//        new Thread(()->{
//            instance.start(Constants.DEFAULT_PORT);
//        }).start();
//        log.info("---------------------------------websocket启动完成！！！------------------------");
//        // 定时向所有客户端发送Ping消息  每个3秒发送一次ping
//        executorService.scheduleAtFixedRate(() ->{
//                    nettyUserManager.broadCastPing();
//                    log.info("--------------------------服务器发送心跳pong-------------------------------");
//                }, 3, 50, TimeUnit.SECONDS);
//        return null;
//    }
//}